package com.hbwxz.rabbitmq;

import com.hbwxz.constant.Constants;
import com.hbwxz.utils.RabbitMqUtils;
import com.rabbitmq.client.Channel;

import java.io.IOException;
import java.util.concurrent.TimeoutException;

/**
 * RabbitMQ 小案例【原生 RabbitMQ，AMQP 导 jar 包的方式搞，生产者 ➕ 消费者】
 * <p>
 * 这里不知道为啥加了 Slf4j 打印日志不出来，不知道是不是不是 javaEE 项目的原因
 *
 * @author shenzw
 * @date 2023/11/9
 */
public class RabbitMqFaceDelete {
    public static void main(String[] args) throws IOException, TimeoutException {

        // 获取 channel
        Channel channel = RabbitMqUtils.getChannel();

        channel.exchangeDelete(Constants.MY_EXCHANGE);
        channel.exchangeDelete(Constants.AE_EXCHANGE);
        channel.exchangeDelete(Constants.DEAD_EXCHANGE);

        channel.queueDelete(Constants.MY_QUEUE);
        channel.queueDelete(Constants.AE_QUEUE);
        channel.queueDelete(Constants.DEAD_QUEUE);

        RabbitMqUtils.close(channel);

    }
}
